package com.zlsy.springbootdemo.rabbitmq.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author zhouliang
 * @date 2020/12/10 14:43
 */
public interface Sink {
  String X_DEATH_INPUT = "input";

  String PARTITION_INTPUT = "partition_intput";

  String ORDINARY_INPUT = "ordinary_input";

  @Input(value = X_DEATH_INPUT)
  SubscribableChannel xDeathInput();

  @Input(value = PARTITION_INTPUT)
  SubscribableChannel partitionIntput();

  @Input(value = ORDINARY_INPUT)
  SubscribableChannel ordinaryInput();
}
